package book.nettyinaction.ch06;

import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;

/**
 *
 * 代码清单 6-9 缓存 ChannelHandlerContext 的引用
 *
 * 此写法不是正确的？ 需要 @Sharable
 *
 */
public class WriteHandler extends ChannelHandlerAdapter {

    private ChannelHandlerContext ctx;

    @Override
    public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
        // 存储 ChannelHandlerContext 的引用以供稍后使用
        this.ctx = ctx;
    }


    public void send( String msg ) {
        // 使用之前存储的 ChannelHandlerContext 的引用来发送消息
        ctx.writeAndFlush( msg );
    }
}
